package cn.z2huo.demo.hello.core.exception;

import lombok.Getter;

/**
 * <p>
 *
 * @author z2huo
 */
@Getter
public class KafkaConsumeException extends RuntimeException {

    private int lastConsumeRecordIndex = -1;

    public KafkaConsumeException(int lastConsumeRecordIndex, String message) {
        super(message);
        this.lastConsumeRecordIndex = lastConsumeRecordIndex;
    }

    public KafkaConsumeException(int lastConsumeRecordIndex, String message, Throwable cause) {
        super(message, cause);
        this.lastConsumeRecordIndex = lastConsumeRecordIndex;
    }

    public KafkaConsumeException(int lastConsumeRecordIndex, Throwable cause) {
        super(cause);
        this.lastConsumeRecordIndex = lastConsumeRecordIndex;
    }

}
